#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2017/5/16 11:04
# @Author  : Leixu
# @Site    : 
# @File    : config.py
# @Software: PyCharm Community Edition

from __future__ import absolute_import
from kombu import Queue, Exchange
from datetime import timedelta
import kombu

CELERY_TASK_RESULT_EXPIRES = 3600
kombu.enable_insecure_serializers()
CELERY_TASK_SERIALIZER = 'pickle'
CELERY_ACCEPT_CONTENT = ['pickle', 'json']
CELERY_RESULT_SERIALIZER = 'pickle'

CELERY_DEFAULT_EXCHANGE = 'agent'
CELERY_DEFAULT_EXCHANGE_TYPE = 'direct'

CELERT_QUEUES = (
    Queue('machine1', exchange='agent', routing_key='machine1'),
    Queue('machine2', exchange='agent', routing_key='machine2'),
)
